package com.guchenbo.spark.core

/**
 * @author guchenbo
 * @date 2022/3/5
 */
object RddFilter {
  def main(args: Array[String]): Unit = {
    val sc = SparkUtils.sc("map")
    val lines = sc.textFile("input/access.log")
    lines.filter(s => {
      val min = s.split(" ")(3).substring(16, 18)
      min.equals("36")
    }).collect().foreach(println)
  }
}
